package cn.me.alphamq.broker.event.model.broker;

import cn.me.alphamq.common.entity.req.ConsumeSuccessReq;
import cn.me.alphamq.common.event.model.Event;

/**
 * 消费成功的事件
 *
 * @author f
 */
public class ConsumeSuccessEvent extends Event {

    /**
     * 消费成功的请求对象
     */
    private ConsumeSuccessReq consumeSuccessReq;

    public ConsumeSuccessEvent() {
    }

    public ConsumeSuccessEvent(ConsumeSuccessReq consumeSuccessReq) {
        this.consumeSuccessReq = consumeSuccessReq;
    }

    public ConsumeSuccessReq getConsumeSuccessReq() {
        return consumeSuccessReq;
    }

    public void setConsumeSuccessReq(ConsumeSuccessReq consumeSuccessReq) {
        this.consumeSuccessReq = consumeSuccessReq;
    }
}
